package com.raja.requestForwarding.mq.config;

import com.raja.fleet.common.Constants;
import org.springframework.amqp.core.Queue;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 定义队列
 * Created by liuyanjun
 * on 2017/7/24.
 */
@Configuration
public class QueueConfig {

    @Value("${fleet.to.service.account}")
    private String fleet_to_service_account;

    @Bean
    public Queue fleetToServiceAccountQueue() {
        return new Queue(fleet_to_service_account);
    }

    @Bean
    public  Queue serviceToFleetAccountQueue() {
        return new Queue(Constants.queues_service_to_fleet_account);
    }

}
